/*
 * @Author: yaohuizhang kaiyun168!@#
 * @Date: 2023-06-01 10:04:44
 * @LastEditors: wangdian
 * @LastEditTime: 2023-08-16 11:17:41
 * @FilePath: \workspace\app.js
 * @Description: 这是默认设置,请设置`customMade`, 打开koroFileHeader查看配置 进行设置: https://github.com/OBKoro1/koro1FileHeader/wiki/%E9%85%8D%E7%BD%AE
 */
const http = require('http');
const wss = require("nodejs-websocket");

// 创建HTTP服务器
const server = http.createServer((req, res) => {
  res.writeHead(200, { 'Content-Type': 'text/plain' });
  res.end('Hello, world!');
});

// 创建WebSocket服务器
// const wss = new WebSocket.Server({ server });

// 监听WebSocket连接事件
wss.on('connection', (ws) => {
  console.log('Client connected.');

    // var lon = 112;
    // var lat = 39;
    // var gj = 0;
    // // 向WebSocket客户端定时发送数据
    // const intervalId = setInterval(() => {
    //     lon += 0.1;
    //     // lat += 0.1;
    //     if (lon >= 180) {
    //         lon = 60;
    //         gj = 1;
    //     } 
    //     if(lat >= 360) {
    //         // lat = 70;
    //     }
    //     ws.send(JSON.stringify(
    //         {
    //             lon:lon,
    //             lat:lat,
    //             height:1000000,
    //             gj:gj
    //         }
    //     ));
    // }, 1000);
    
    var num = 0;
    // 向WebSocket客户端定时发送数据
    const intervalId = setInterval(() => {
        num++
        var data = [];
        if(num% 2 == 0){
          for(var i = 0; i < 100000;i++){
            data.push([i, i]);
          }
        }else{
          for(var i = 0; i < 80000;i++){
            data.push([i, i]);
          }
        }
        
        
        ws.send(JSON.stringify(
          data
        ));
    }, 1000);
  // 监听WebSocket关闭事件
  ws.on('close', () => {
    console.log('Client disconnected.');
    clearInterval(intervalId);
  });
});

// 启动HTTP服务器并开始监听请求
server.listen(3000, () => {
  console.log('Server listening on port 3000');
});
